const express = require('express')
const router = express.Router()
const mysql = require('mysql')

const db = {
    host: '127.0.0.1', // 新建数据库连接时的 主机名或ID地址 内容
    user: 'root', // 连接的数据用户名
    password: '123456', // 密码
    database: 'demo1', // 数据库名
    port: '3306'
  }

  // 创建连接池
const pool = mysql.createPool({...db,...{connectionLimit:10}});
  
// 查询函数
function query(sql, callback) {
  // 从连接池中获取一个连接
  pool.getConnection((err, connection) => {
    if (err) {
      callback(err, null);
    } else {

      // 执行查询
      connection.query(sql, (err, results) => {
        // 释放连接
        connection.release();
        callback(err, results);
      });
    }
  });
}

// 写入
router.post('/addmysql',(req,res) => {
    let sql = ` insert into data1 (name, age) values('liang',18)`
    query(sql,(err,result) => {
        if(err) {
            console.log(err);
            res.status(500).json({message:'失败'})
            return
        }else{
            res.status(200).json({message:'OK'})
            return
        }
    })
})
// 读取
router.post('/serchmysql',(req,res) => {
    let sql = ` select * from data1`
    query(sql,(err,result) => {
        if(err) {
            console.log(err);
            res.status(500).json({message:'失败'})
            return
        }else{
            // res.status(200).json({message:result})
            res.status(200).json({message:result})
            return
        }
    })
})



module.exports = router